package com.bw.consumer;

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

@Component
@RocketMQMessageListener(consumerGroup = "test-test", topic = "yanshi5")
public class OrderConsumer implements RocketMQListener<String> {
    @Override
    public void onMessage(String orderId) {

        // 判断这个订单有没有支付  如果没有支付  关闭订单

    }
}
